import os
from celery import Celery

from OA_pro import settings

os.environ.setdefault('DJANGO_SETTINGS_MODULE', "OA_pro.settings")

# 创建celery对象
# main 是给所有任务添加前缀信息
app = Celery(main="cc")

# 加载配置文件

# 消息中间人broker设置
app.conf.broker_url = 'redis://127.0.0.1:6379/15'
# 结果存储设置
app.conf.result_backend = 'redis://127.0.0.1:6379/14'

# 自动发现项目中所有的任务
app.autodiscover_tasks(settings.INSTALLED_APPS)

# celery -A utils.My_celery worker --loglevel=info -P eventlet
